package com.learn.kafka.simple;

import com.learn.kafka.config.ProducerProperties;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;

/**
 * @author: learn.kafka
 */
public class  SimpleProducer extends ProducerProperties {
    public static void main(String[] args) {
        // 创建生产者实例（自动调用父类构造方法初始化配置）
        SimpleProducer producer = new SimpleProducer();
        producer.startProducing();
    }

    // 发送消息的方法
    private void startProducing() {
        // 从父类获取配置，初始化 Kafka 生产者
        Producer<Integer, String> producer = new KafkaProducer<>(super.getProps());

        // 发送 10 条测试消息
        for (int i = 0; i < 10; i++) {
            producer.send(new ProducerRecord<>("mytopic", i, Integer.toString(i)));
        }

        // 关闭生产者（确保消息发送完成）
        producer.close();
    }
}
